// 版权所有2009 Go作者。保留所有权利。
// 此源代码的使用受BSD样式
// 许可证的约束，该许可证可以在许可证文件中找到。

package runtime

import (
	"internal/abi"
	"internal/goarch"
	"runtime/internal/atomic"
	"runtime/internal/syscall"
	"unsafe"
)

// sigPerThreadSyscall是glibc在Linux上对
// per-thread系统调用使用的相同信号（SIGSETXID）。我们在非cgo 
// 二进制文件中也使用它。
const sigPerThreadSyscall = _SIGRTMIN + 1

type mOS struct {
	// profileTimer保存用于分析CPU的POSIX间隔计时器的ID 
	// 此线程上的使用情况。
	// 
	// 当profileTimerValid字段非零时有效。线程
	// 创建并管理自己的计时器，这些字段仅由该线程读取和写入。但由于profileTimerValid 
	// 上的一些读取是在信号处理代码中进行的，因此对该字段的访问使用原子操作。
	profileTimer      int32
	profileTimerValid uint32

	// needPerThreadSyscall表示DoAllThreadSysCall需要每个线程的系统调用
	// 。
	needPerThreadSyscall atomic.Uint8
}

// go:noescape 
func futex(addr unsafe.Pointer, op int32, val uint32, ts, addr2 unsafe.Pointer, val3 uint32) int32

// Linux futex。
// 
// futexsleep（uint32*addr，uint32 val）
// futexwakeup（uint32*addr）
// 
// futexsleep会自动检查*addr==val，如果是，则睡在addr上。
// Futexwakeup唤醒在addr上睡眠的线程。
// Futexsleep可以被允许冒充醒来。

const (
	_FUTEX_PRIVATE_FLAG = 128
	_FUTEX_WAIT_PRIVATE = 0 | _FUTEX_PRIVATE_FLAG
	_FUTEX_WAKE_PRIVATE = 1 | _FUTEX_PRIVATE_FLAG
)

// 原子上，
// 如果（*addr==val）睡眠
// 可能会被错误唤醒；这是允许的。
// 睡眠时间不要超过纳秒；ns<0表示永远。
// go:nosplit 
func futexsleep(addr *uint32, val uint32, ns int64) {
	// 一些Linux内核有一个bug，其中futex of 
	// futex_WAIT返回一个内部错误代码
	// 作为错误号。Libpthread忽略返回值
	// 在这里，我们也可以忽略：正如它所说的几行，
	// 允许虚假唤醒。
	if ns < 0 {
		futex(unsafe.Pointer(addr), _FUTEX_WAIT_PRIVATE, val, nil, nil, 0)
		return
	}

	var ts timespec
	ts.setNsec(ns)
	futex(unsafe.Pointer(addr), _FUTEX_WAIT_PRIVATE, val, unsafe.Pointer(&ts), nil, 0)
}

// 如果有任何进程正在addr上睡觉，最多醒来一次。我不知道futex Wake Up是否可以返回
func futexwakeup(addr *uint32, cnt uint32) {
	ret := futex(unsafe.Pointer(addr), _FUTEX_WAKE_PRIVATE, cnt, nil, nil, 0)
	if ret >= 0 {
		return
	}

	// EAGAIN或EINTR，但如果它返回，则可以安全地再次循环并调用futex。
	systemstack(func() {
		print("futexwakeup addr=", addr, " returned ", ret, "\n")
	})

	*(*int32)(unsafe.Pointer(uintptr(0x1006))) = 0x1006
}

func getproccount() int32 {
	// 这个缓冲区很大（8KB），但我们在系统堆栈上
	// 应该有足够的空间（64KB）。
	// 这也是一片叶子，所以我们不会长时间保留记忆。
	// 见golang。org/issue/11823。
	// 这里建议的行为是继续尝试使用越来越大的
	// 缓冲区，但我们在
	// 时刻没有动态内存分配程序，所以这有点棘手，似乎有些过头了。
	const maxCPUs = 64 * 1024
	var buf [maxCPUs / 8]byte
	r := sched_getaffinity(0, unsafe.Sizeof(buf), &buf[0])
	if r < 0 {
		return 1
	}
	n := int32(0)
	for _, v := range buf[:r] {
		for v != 0 {
			n += int32(v & 1)
			v >>= 1
		}
	}
	if n == 0 {
		n = 1
	}
	return n
}

// 克隆，Linux rfork。
const (
	_CLONE_VM             = 0x100
	_CLONE_FS             = 0x200
	_CLONE_FILES          = 0x400
	_CLONE_SIGHAND        = 0x800
	_CLONE_PTRACE         = 0x2000
	_CLONE_VFORK          = 0x4000
	_CLONE_PARENT         = 0x8000
	_CLONE_THREAD         = 0x10000
	_CLONE_NEWNS          = 0x20000
	_CLONE_SYSVSEM        = 0x40000
	_CLONE_SETTLS         = 0x80000
	_CLONE_PARENT_SETTID  = 0x100000
	_CLONE_CHILD_CLEARTID = 0x200000
	_CLONE_UNTRACED       = 0x800000
	_CLONE_CHILD_SETTID   = 0x1000000
	_CLONE_STOPPED        = 0x2000000
	_CLONE_NEWUTS         = 0x4000000
	_CLONE_NEWIPC         = 0x8000000

	// 从QEMU 2.8.0（5ea2fc84d）开始，用户仿真要求在创建线程时设置所有六个
	// 标志；尝试共享另一个
	// 5，但不共享SYSVSEM，将因-EINVAL而失败。
	// 
	// 在非QEMU环境中，克隆系统是无关紧要的，因为我们不使用System V信号量。

	cloneFlags = _CLONE_VM | /* share memory */
		_CLONE_FS | /* share cwd, etc */
		_CLONE_FILES | /* share fd table */
		_CLONE_SIGHAND | /* share sig handler table */
		_CLONE_SYSVSEM | /* share SysV semaphore undo lists (see issue #20763) */
		_CLONE_THREAD /* revisit - okay for now */
)

// go:noescape 
func clone(flags int32, stk, mp, gp, fn unsafe.Pointer) int32

// 可以在m.p==nil的情况下运行，因此不允许使用写屏障。
// go:nowritebarrier 
func newosproc(mp *m) {
	stk := unsafe.Pointer(mp.g0.stack.hi)
	/*
	 * note: strace gets confused if we use CLONE_PTRACE here.
	 */
	if false {
		print("newosproc stk=", stk, " m=", mp, " g=", mp.g0, " clone=", abi.FuncPCABI0(clone), " id=", mp.id, " ostk=", &mp, "\n")
	}

	// 在克隆期间禁用信号，以便新线程在禁用信号的情况下启动
	// 。这将使他们在minit。
	var oset sigset
	sigprocmask(_SIG_SETMASK, &sigset_all, &oset)
	ret := clone(cloneFlags, stk, unsafe.Pointer(mp), unsafe.Pointer(mp.g0), unsafe.Pointer(abi.FuncPCABI0(mstart)))
	sigprocmask(_SIG_SETMASK, &oset, nil)

	if ret < 0 {
		print("runtime: failed to create new OS thread (have ", mcount(), " already; errno=", -ret, ")\n")
		if ret == -_EAGAIN {
			println("runtime: may need to increase max user processes (ulimit -u)")
		}
		throw("newosproc")
	}
}

// 不需要有效G的newosproc版本。
// go:nosplit 
func newosproc0(stacksize uintptr, fn unsafe.Pointer) {
	stack := sysAlloc(stacksize, &memstats.stacks_sys)
	if stack == nil {
		write(2, unsafe.Pointer(&failallocatestack[0]), int32(len(failallocatestack)))
		exit(1)
	}
	ret := clone(cloneFlags, unsafe.Pointer(uintptr(stack)+stacksize), nil, nil, fn)
	if ret < 0 {
		write(2, unsafe.Pointer(&failthreadcreate[0]), int32(len(failthreadcreate)))
		exit(1)
	}
}

var failallocatestack = []byte("runtime: failed to allocate stack for the new OS thread\n")
var failthreadcreate = []byte("runtime: failed to create new OS thread\n")

const (
	_AT_NULL   = 0  // 向量结束
	_AT_PAGESZ = 6  // 系统物理页面大小
	_AT_HWCAP  = 16 // 硬件能力位向量
	_AT_RANDOM = 25 // 在2.6.29 
)

var procAuxv = []byte("/proc/self/auxv\x00")

var addrspace_vec [1]byte

func mincore(addr unsafe.Pointer, n uintptr, dst *byte) int32

func sysargs(argc int32, argv **byte) {
	n := argc + 1

	// 跳过argv，envp进入auxv 
	for argv_index(argv, n) != nil {
		n++
	}

	// 跳过空分隔符
	n++

	// 现在argv+n是auxv 
	auxv := (*[1 << 28]uintptr)(add(unsafe.Pointer(argv), uintptr(n)*goarch.PtrSize))
	if sysauxv(auxv[:]) != 0 {
		return
	}
	// 在某些情况下，我们无法获得
	// auxv提供的加载程序，例如在Android上作为库加载时。
	// 返回到/proc/self/auxv。
	fd := open(&procAuxv[0], 0 /* O_RDONLY */, 0)
	if fd < 0 {
		// 在Android上，/proc/self/auxv可能无法读取（9229期），因此我们回到
		// 尝试使用mincore检测物理页面大小。
		// 当地址不是系统页面大小的倍数时，mincore应返回EINVAL。
		const size = 256 << 10 // 要分配的内存区域大小
		p, err := mmap(nil, size, _PROT_READ|_PROT_WRITE, _MAP_ANON|_MAP_PRIVATE, -1, 0)
		if err != 0 {
			return
		}
		var n uintptr
		for n = 4 << 10; n < size; n <<= 1 {
			err := mincore(unsafe.Pointer(uintptr(p)+n), 1, &addrspace_vec[0])
			if err == 0 {
				physPageSize = n
				break
			}
		}
		if physPageSize == 0 {
			physPageSize = size
		}
		munmap(p, size)
		return
	}
	var buf [128]uintptr
	n = read(fd, noescape(unsafe.Pointer(&buf[0])), int32(unsafe.Sizeof(buf)))
	closefd(fd)
	if n < 0 {
		return
	}
	// 确保buf被终止，即使我们没有读取整个文件。
	buf[len(buf)-2] = _AT_NULL
	sysauxv(buf[:])
}

// startupRandomData保存启动时初始化的随机字节。这些来自
// ELF AT_随机辅助向量。内核提供了一个指向16字节随机数据的指针。
var startupRandomData []byte

func sysauxv(auxv []uintptr) int {
	var i int
	for ; auxv[i] != _AT_NULL; i += 2 {
		tag, val := auxv[i], auxv[i+1]
		switch tag {
		case _AT_RANDOM:
			startupRandomData = (*[16]byte)(unsafe.Pointer(val))[:]

		case _AT_PAGESZ:
			physPageSize = val
		}

		archauxv(tag, val)
		vdsoauxv(tag, val)
	}
	return i / 2
}

var sysTHPSizePath = []byte("/sys/kernel/mm/transparent_hugepage/hpage_pmd_size\x00")

func getHugePageSize() uintptr {
	var numbuf [20]byte
	fd := open(&sysTHPSizePath[0], 0 /* O_RDONLY */, 0)
	if fd < 0 {
		return 0
	}
	ptr := noescape(unsafe.Pointer(&numbuf[0]))
	n := read(fd, ptr, int32(len(numbuf)))
	closefd(fd)
	if n <= 0 {
		return 0
	}
	n-- // 删除尾随换行符
	v, ok := atoi(slicebytetostringtmp((*byte)(ptr), int(n)))
	if !ok || v < 0 {
		v = 0
	}
	if v&(v-1) != 0 {
		// v不是2 
		return 0
	}
	return uintptr(v)
}

func osinit() {
	ncpu = getproccount()
	physHugePageSize = getHugePageSize()
	if iscgo {
		// /42494Glibc和musl为
		// 内部使用保留一些信号，并要求它们不被
		// 正常C运行时的其余部分阻塞。当go运行时
		// 阻塞时。。。解除信号封锁，暂时封锁
		// 时间间隔一般很短。因此，
		// 这些对*libc代码的期望主要由
		// 组合的go+cgo线程系统来满足。但是，当go导致线程退出时，通过从
		// mstart（）返回，如果
		// 这些信号被阻止，组合运行时可能会死锁。因此，退出线程时不要阻止这些
		// 信号。
		// /-glibc:SIGCANCEL（32）、SIGSETXID（33）
		// /-musl:SIGTIMER（32）、SIGCANCEL（33）、sigconcall（34）
		sigdelset(&sigsetAllExiting, 32)
		sigdelset(&sigsetAllExiting, 33)
		sigdelset(&sigsetAllExiting, 34)
	}
	osArchInit()
}

var urandom_dev = []byte("/dev/urandom\x00")

func getRandomData(r []byte) {
	if startupRandomData != nil {
		n := copy(r, startupRandomData)
		extendRandom(r, n)
		return
	}
	fd := open(&urandom_dev[0], 0 /* O_RDONLY */, 0)
	n := read(fd, unsafe.Pointer(&r[0]), int32(len(r)))
	closefd(fd)
	extendRandom(r, int(n))
}

func goenvs() {
	goenvs_unix()
}

// /调用以同步初始化使用
// /-buildmode=c-archive或-buildmode=c-shared构建的Go代码。
// Go运行时均未初始化。
// go:nosplit 
// go:nowritebarrierrec 
func libpreinit() {
	initsig(true)
}

// 调用以初始化新的m（包括引导程序m）。
// 在父线程（引导时为主线程）上调用，可以分配内存。
func mpreinit(mp *m) {
	mp.gsignal = malg(32 * 1024) // Linux想要>=2K 
	mp.gsignal.m = mp
}

func gettid() uint32

// 调用以初始化新的m（包括引导程序m）。
// 在新线程上被调用，无法分配内存。
func minit() {
	minitSignals()

	// Cgo创建的线程和引导程序m缺少一个
	// procid。我们需要这个用于异步抢占，它在调试器中非常有用。
	getg().m.procid = uint64(gettid())
}

// 从dropm调用以撤消minit的效果。
// go:nosplit 
func unminit() {
	unminitSignals()
}

// 从exitm调用，而不是从drop调用，以撤销线程拥有的
// minit、semacreate或其他资源的效果。打完电话后不要带锁。（6）6
func mdestroy(mp *m) {
}


func sigreturn()
func cgoSigtramp()

func sigaltstack(new, old *stackt)

func setitimer(mode int32, new, old *itimerval)

func timer_create(clockid int32, sevp *sigevent, timerid *int32) int32

func timer_settime(timerid int32, flags int32, new, old *itimerspec) int32

func timer_delete(timerid int32) int32

func rtsigprocmask(how int32, new, old *sigset, size int32)

// go:nowritebarrierrec-
func sigprocmask(how int32, new, old *sigset) {
	rtsigprocmask(how, new, old, int32(unsafe.Sizeof(*new)))
}

func raise(sig uint32)
func raiseproc(sig uint32)

// go:noescape-
func sched_getaffinity(pid, len uintptr, buf *byte) int32
func osyield()

// go:nosplit-
func osyield_no_g() {
	osyield()
}

func pipe() (r, w int32, errno int32)
func pipe2(flags int32) (r, w int32, errno int32)
func setNonblock(fd int32)

const (
	_si_max_size    = 128
	_sigev_max_size = 64
)

// go:nosplit-
// go:nowritebarrierrec-
func setsig(i uint32, fn uintptr) {
	var sa sigactiont
	sa.sa_flags = _SA_SIGINFO | _SA_ONSTACK | _SA_RESTORER | _SA_RESTART
	sigfillset(&sa.sa_mask)
	// 尽管Linux主页上说“sa_restorer元素已经过时，
	// 不应该被使用”。x86_64内核需要它。只能在
	// x86上使用。
	if GOARCH == "386" || GOARCH == "amd64" {
		sa.sa_restorer = abi.FuncPCABI0(sigreturn)
	}
	if fn == abi.FuncPCABIInternal(sighandler) { // abi。FuncPCABIInternal（sighandler）匹配signal_unix中的调用者。go-
		if iscgo {
			fn = abi.FuncPCABI0(cgoSigtramp)
		} else {
			fn = abi.FuncPCABI0(sigtramp)
		}
	}
	sa.sa_handler = fn
	sigaction(i, &sa, nil)
}

// go:nosplit-
// go:nowritebarrierrec-
func setsigstack(i uint32) {
	var sa sigactiont
	sigaction(i, nil, &sa)
	if sa.sa_flags&_SA_ONSTACK != 0 {
		return
	}
	sa.sa_flags |= _SA_ONSTACK
	sigaction(i, &sa, nil)
}

// go:nosplit-
// go:nowritebarrierrec-
func getsig(i uint32) uintptr {
	var sa sigactiont
	sigaction(i, nil, &sa)
	return sa.sa_handler
}

// setSignaltstackSP设置堆栈的ss_sp字段。
// go:nosplit 
func setSignalstackSP(s *stackt, sp uintptr) {
	*(*uintptr)(unsafe.Pointer(&s.ss_sp)) = sp
}

// go:nosplit 
func (c *sigctxt) fixsigcode(sig uint32) {
}

// sysSigaction调用rt_sigaction系统调用。
// go:nosplit 
func sysSigaction(sig uint32, new, old *sigactiont) {
	if rt_sigaction(uintptr(sig), new, old, unsafe.Sizeof(sigactiont{}.sa_mask)) != 0 {
		// 解决QEMU用户模式模拟中的错误。
		// 
		// QEMU将对sigaction系统调用的调用转换为对C库sigaction调用的调用；C 
		// 库调用拒绝为
		// SIGCANCEL（32）或SIGSETXID（33）调用sigaction的尝试。
		// 
		// QEMU拒绝在SIGRTMAX（64）上调用sigaction。
		// 
		// 在这种情况下忽略错误。无论如何我们都无能为力。
		if sig != 32 && sig != 33 && sig != 64 {
			// 使用系统堆栈避免ppc64/ppc64le上的拆分堆栈溢出。
			systemstack(func() {
				throw("sigaction failed")
			})
		}
	}
}

// rt_sigaction在汇编中实现。
// go:noescape 
func rt_sigaction(sig uintptr, new, old *sigactiont, size uintptr) int32

func getpid() int
func tgkill(tgid, tid, sig int)

// signalM向mp发送信号。
func signalM(mp *m, sig int) {
	tgkill(getpid(), int(mp.procid), sig)
}

// go118UseTimerCreateProfiler启用每线程CPU探查器。
const go118UseTimerCreateProfiler = true

// validSIGPROF将此信号传递的代码与探查器使用的信号源
// 进行比较，返回是否应处理传递。
// 要处理，来自已知分析机制的信号传递应该与此线程可用的最佳分析机制相对应。来自其他来源的信号
// 始终被认为是有效的。
// 
// go:nosplit 
func validSIGPROF(mp *m, c *sigctxt) bool {
	code := int32(c.sigcode())
	setitimer := code == _SI_KERNEL
	timer_create := code == _SI_TIMER

	if !(setitimer || timer_create) {
		// 该信号与
		// 运行时启用的分析机制不对应。没有理由处理它，但也没有理由忽视它。
		return true
	}

	if mp == nil {
		// 由于我们没有M，因此无法检查此线程的每个线程计时器是否有活动
		// 。我们不知道这个线程
		// 已经存在了多长时间，也不知道它是否碰巧在评测处于活动状态时与Go调度程序
		// 进行了交互（导致它有一个每线程
		// 计时器）。但它可能从未与Go调度程序进行过交互，或者在评测处于活动状态时从未与
		// 进行过交互。为避免重复计数，只处理来自setitimer的信号。
		// 
		// 当注册了自定义cgo回溯函数（在
		// 支持runtime.SetCgoTraceback的平台上）时，SIGPROF会向找不到匹配M的线程发送
		// 信号，在
		// runtime的程序集实现中执行此检查。cgoSigtramp。
		return setitimer
	}

	// 有一个M意味着线程与Go调度程序交互，我们可以检查这个线程是否有一个活动的每线程计时器。
	if atomic.Load(&mp.profileTimerValid) != 0 {
		// 如果此M有自己的每线程CPU分析间隔计时器，我们
		// 应该跟踪来自该计时器的SIGPROF信号（对于
		// 准确报告其CPU使用情况；请参阅问题35057），并忽略它从进程范围的setItemer获得的任何
		// CPU消耗量（不要过度计算其
		// CPU消耗）。
		return timer_create
	}

	// 没有活动的每线程计时器意味着唯一有效的探查器是setitimer。
	return setitimer
}

func setProcessCPUProfiler(hz int32) {
	setProcessCPUProfilerTimer(hz)
}

func setThreadCPUProfiler(hz int32) {
	mp := getg().m
	mp.profilehz = hz

	if !go118UseTimerCreateProfiler {
		return
	}

	// 销毁任何活动计时器
	if atomic.Load(&mp.profileTimerValid) != 0 {
		timerid := mp.profileTimer
		atomic.Store(&mp.profileTimerValid, 0)
		mp.profileTimer = 0

		ret := timer_delete(timerid)
		if ret != 0 {
			print("runtime: failed to disable profiling timer; timer_delete(", timerid, ") errno=", -ret, "\n")
			throw("timer_delete")
		}
	}

	if hz == 0 {
		// 如果目标是禁用此线程的分析，则任务完成。
		return
	}

	// 定时器的周期应为1/Hz。对于每增加一个“1/Hz”的
	// 工作，用户应该期望配置文件中增加一个样本。
	// 
	// 但要缩减到非常少量的应用程序工作，观察
	// 甚至CPU使用率为请求周期的“十分之一”，以不同的方式设置初始
	// 定时延迟：使CPU 
	// 花费周期的“十分之一”显示为一个样本的10%概率（对于
	// 0.1个样本的预期值），因此，CPU消耗的“十分之二和十分之六”时间段显示，
	// 三个样本的概率增加了60%，两个样本的概率增加了40%（对于
	// 预期值为2.6）。将初始延迟设置为unifom 
	// 随机分布中0和所需周期之间的值。因为“0”
	// 表示“禁用计时器”，加1，使半开区间[0，句号）将
	// 变成（0，句号）.
	// 
	// 否则，这将显示为对短期线程和偶尔活动的线程的偏向：例如，当
	// 垃圾收集器在基本空闲的系统上运行时，
	// 激活的额外线程可能会在探查器观察到的几秒钟内完成几毫秒与GC相关的工作，而不会执行任何其他任务。
	spec := new(itimerspec)
	spec.it_value.setNsec(1 + int64(fastrandn(uint32(1e9/hz))))
	spec.it_interval.setNsec(1e9 / int64(hz))

	var timerid int32
	var sevp sigevent
	sevp.notify = _SIGEV_THREAD_ID
	sevp.signo = _SIGPROF
	sevp.sigev_notify_thread_id = int32(mp.procid)
	ret := timer_create(_CLOCK_THREAD_CPUTIME_ID, &sevp, &timerid)
	if ret != 0 {
		// 如果我们无法为此M创建计时器，请保留profileTimerValid false 
		// 返回到进程范围的setitimer分析器。
		return
	}

	ret = timer_settime(timerid, 0, spec, nil)
	if ret != 0 {
		print("runtime: failed to configure profiling timer; timer_settime(", timerid,
			", 0, {interval: {",
			spec.it_interval.tv_sec, "s + ", spec.it_interval.tv_nsec, "ns} value: {",
			spec.it_value.tv_sec, "s + ", spec.it_value.tv_nsec, "ns}}, nil) errno=", -ret, "\n")
		throw("timer_settime")
	}

	mp.profileTimer = timerid
	atomic.Store(&mp.profileTimerValid, 1)
}

// perThreadSyscallArgs包含系统调用号、参数和
// 在所有线程上执行的系统调用的预期返回值。
type perThreadSyscallArgs struct {
	trap uintptr
	a1   uintptr
	a2   uintptr
	a3   uintptr
	a4   uintptr
	a5   uintptr
	a6   uintptr
	r1   uintptr
	r2   uintptr
}

// perThreadSyscall是为正在进行的
// doAllThreadsSyscall执行的系统调用。
// 
// perThreadSyscall只能在mp时写入。needPerThreadSyscall==0（在
// all Ms.
var perThreadSyscall perThreadSyscallArgs

// syscall_runtime_DoAllThreadSysCall上）并在
// all Ms 
// 
// 系统调用应成功，并在每个
// 线程上返回相同的值。如果有任何线程不匹配，运行时将抛出。
// 
// go:linkname syscall\u runtime\u doAllThreadsSyscall syscall。runtime_doAllThreadsSyscall 
// go:uintTrescapes 
func syscall_runtime_doAllThreadsSyscall(trap, a1, a2, a3, a4, a5, a6 uintptr) (r1, r2, err uintptr) {
	if iscgo {
		// 在cgo中，我们不知道在C中创建的线程，所以这种方法不起作用。
		panic("doAllThreadsSyscall not supported with cgo enabled")
	}

	// STW以确保用户goroutines看到线程
	// state的原子更改。如果没有STW，goroutines可以在
	// 进程中进行更改时迁移Ms，例如，请参见状态旧->新->旧->新。
	// 
	// N.B.在内部，此函数不依赖于STW来成功更改每个线程。仅用户
	// 根据上述要求需要。
	stopTheWorld("doAllThreadsSyscall")

	// 此函数依赖于几个属性：
	// 
	// 1。所有已经存在的OS线程都与
	// allm中的M关联。i、 例如，我们不会错过任何预先存在的线程。
	// 2。allm中列出的所有Ms最终都会有一个OS线程存在。
	// 也就是说，他们将设置procid并能够接收信号。
	// 3。我们读取allm后创建的OS线程将从执行系统调用的线程
	// 克隆。i、 例如，他们继承了
	// 修改状态。我们通过不同的机制实现这些目标：
	// 
	// 1。在allocm中向allm添加新的Ms发生在稍后在newm中克隆其
	// OS线程之前。
	// 2。newm确实收购了M以避免被抢占，从而确保在allocm中创建的新Ms 
	// 最终将在
	// newm中到达OS线程克隆。
	// 3。我们在这里使用allocmLock进行写入，以防止在该函数运行时分配新的Ms 
	// 。根据（1），这将防止克隆尚未在allm中的OS 
	// 线程。
	allocmLock.lock()

	// 禁用抢占，防止我们更改Ms，因为我们专门处理
	// 此M。
	// 
	// N.B.上面的STW和lock（）也可以这样做，这是为了额外的
	// 。
	acquirem()

	// N.B.allocmLock还阻止此函数的并发执行，
	// perThreadSyscall，mp的序列化使用。needPerThreadSyscall和
	// 确保所有线程以相同的顺序执行来自多个调用的系统调用。

	r1, r2, errno := syscall.Syscall6(trap, a1, a2, a3, a4, a5, a6)
	if GOARCH == "ppc64" || GOARCH == "ppc64le" {
		// 待办事项（https:
		r2 = 0
	}
	if errno != 0 {
		releasem(getg().m)
		allocmLock.unlock()
		startTheWorld()
		return r1, r2, errno
	}

	perThreadSyscall = perThreadSyscallArgs{
		trap: trap,
		a1:   a1,
		a2:   a2,
		a3:   a3,
		a4:   a4,
		a5:   a5,
		a6:   a6,
		r1:   r1,
		r2:   r2,
	}

	// 等待所有线程启动。
	// 
	// 如上所述，在
	// allocmLock之前，已经向allm添加了一些M，但尚未完成操作系统克隆和设置procid。
	// 
	// 至少我们必须等待线程设置procid，然后才能发送信号。
	// 
	// 
	// 我们更进一步，等待所有线程启动
	// 然后再发送任何信号。这将防止系统调用两次应用
	// 一次应用于父级，一次应用于子级，如下所示：
	// 
	// A B C 
	// 将C添加到所有M 
	// doAllThreadsSyscall 
	// AllocBlock。lock（）
	// 信号B 
	// /<receive signal>
	// 执行系统调用
	// /<signal return>
	// 克隆C 
	// /<thread start>
	// 设置procid 
	// 信号C 
	// <receive signal>
	// 执行系统调用
	// <signal return>
	// /
	// 在这种情况下，线程C从
	// 线程B继承了系统调用修改状态，不需要执行系统调用，但还是执行了
	// 因为doAllThreadsSyscall无法确定它是否是
	// 必需的。
	// 
	// 某些系统调用可能不是幂等的，因此我们确保每个线程
	// 只执行一次系统调用。
	for mp := allm; mp != nil; mp = mp.alllink {
		for atomic.Load64(&mp.procid) == 0 {
			// 线程正在启动。
			osyield()
		}
	}

	// 每隔一个线程发送一个信号，它们将在信号处理程序中执行perThreadSyscall 
	// 。
	gp := getg()
	tid := gp.m.procid
	for mp := allm; mp != nil; mp = mp.alllink {
		if atomic.Load64(&mp.procid) == tid {
			// 我们的线程已经执行了系统调用。
			continue
		}
		mp.needPerThreadSyscall.Store(1)
		signalM(mp, sigPerThreadSyscall)
	}

	// 等待所有线程完成。
	for mp := allm; mp != nil; mp = mp.alllink {
		if mp.procid == tid {
			continue
		}
		for mp.needPerThreadSyscall.Load() != 0 {
			osyield()
		}
	}

	perThreadSyscall = perThreadSyscallArgs{}

	releasem(getg().m)
	allocmLock.unlock()
	startTheWorld()

	return r1, r2, errno
}

// runPerThreadSyscall在需要时为此M运行perThreadSyscall。
// 
// 如果系统调用返回除
// 预期值以外的任何值，则此函数将引发。
// go:nosplit 
func runPerThreadSyscall() {
	gp := getg()
	if gp.m.needPerThreadSyscall.Load() == 0 {
		return
	}

	args := perThreadSyscall
	r1, r2, errno := syscall.Syscall6(args.trap, args.a1, args.a2, args.a3, args.a4, args.a5, args.a6)
	if GOARCH == "ppc64" || GOARCH == "ppc64le" {
		// TODO（https:
		r2 = 0
	}
	if errno != 0 || r1 != args.r1 || r2 != args.r2 {
		print("trap:", args.trap, ", a123456=[", args.a1, ",", args.a2, ",", args.a3, ",", args.a4, ",", args.a5, ",", args.a6, "]\n")
		print("results: got {r1=", r1, ",r2=", r2, ",errno=", errno, "}, want {r1=", args.r1, ",r2=", args.r2, ",errno=0\n")
		throw("AllThreadsSyscall6 results differ between threads; runtime corrupted")
	}

	gp.m.needPerThreadSyscall.Store(0)
}
